package cn.liwq.demo.disruptor;

import com.lmax.disruptor.EventHandler;
import lombok.AllArgsConstructor;
import lombok.extern.slf4j.Slf4j;

/**
 * @author lweiqiang
 * @date 2023/5/4
 */
@Slf4j
@AllArgsConstructor
public class TaskResultEventHandler implements EventHandler<TaskEvent> {
    @Override
    public void onEvent(TaskEvent taskEvent, long l, boolean b) throws Exception {
        log.info("result handle {}-{}", l, taskEvent.getContent());
    }
}
